bde2d91cd9d5f1b03f78b162a484b563dcf9a59e,community/kernel/src/test/java/org/neo4j/kernel/impl/store/countStore/InMemoryCountsStoreIntegrationTest.java,InMemoryCountsStoreIntegrationTest,concurrentWorkload,#,91

Before Change


            if ( i > 1 && ThreadLocalRandom.current().nextInt( 50 ) == 3 )
            {
                //THEN
                snapshotExecutorService.execute( new SnapshotWorker( i, intermediateStateTestManager, countStore ) );
            }
        }
        workerExecutorService.shutdown();

After Change


        ExecutorService executor = Executors.newFixedThreadPool( 10 );
        ExecutorCompletionService<Void> ecs = new ExecutorCompletionService<>( executor );

        List<Runnable> workers = new ArrayList<>( 10 );
        AtomicBoolean stop = new AtomicBoolean();
        for ( int i = 0; i < 9; i++ )
        {
            workers.add( new UpdateWorker( stop, intermediateStateTestManager, countStore ) );
        }
        workers.add( new SnapshotWorker( 10, stop, intermediateStateTestManager, countStore ) );

        //WHEN
        for ( Runnable worker : workers )